/*package com.swdegao.iot.netty.utils;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;

import com.swdegao.iot.netty.server.channelhandler.ParseMessgaeHandler;


@Component
@Repository
@RocketMQMessageListener(topic = "topicOne", consumerGroup = "java_consumer_group")
public class MyConsumer implements RocketMQListener<String> {
	private final static Logger logger = LoggerFactory.getLogger(ParseMessgaeHandler.class);
    public void onMessage(String message) {
    	logger.info("received message: " + message);
    }
}

*/